package com.example;

import com.example.generator.DataGenerator;
import java.util.Properties;

public class DataSimulatorMain {
    public static void main(String[] args) {
        // 配置Kafka生产者属性
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        DataGenerator generator = new DataGenerator(props);

        try {
            // 生成Canal格式数据
            System.out.println("开始生成Canal格式数据...");
            generator.generateCanalData("canal-topic", 10);
            System.out.println("Canal格式数据生成完成！");

            // 生成OGG格式数据
            System.out.println("开始生成OGG格式数据...");
            generator.generateOGGData("ogg-topic", 10);
            System.out.println("OGG格式数据生成完成！");
        } finally {
            generator.close();
        }
    }
} 